# 定义命名空间
namespace java Services.RocketMqConsumer
namespace php Services.RocketMqConsumer

struct Result {
	1: i32 code
	2: string msg
	3: optional string result
}

# 消息
struct MessageInfo {
    1: string message_id;                                
    2: string topic;			                    
    3: string tags;
    4: string msg;
    5: optional string key;
    6: optional string shardingKey;
}

# 定义服务
service RocketMqConsumer {

  	// 接收消息
    Result receiveMsg(1: MessageInfo message)
    
}